package com.atzc.utils.filter;

import org.apache.flink.api.common.functions.FilterFunction;


public class ContainsFilterFunc implements FilterFunction<String> {

    public String logContains = "";

    public ContainsFilterFunc(String logContains) {
        this.logContains = logContains;
    }

    @Override
    public boolean filter(String s) throws Exception {
        return  s.contains(logContains);
    }
}
